package com.lingdian.demo.rabbitmq;

import java.io.IOException;
import java.io.Serializable;

import org.springframework.util.SerializationUtils;

public class Producer extends EndPoint{

	public Producer(String endpointName) throws IOException {
		super(endpointName);
	}
	public void sendMessage(Serializable object) throws IOException {
	    channel.basicPublish("",endPointName, null, SerializationUtils.serialize(object));
	}

}
